package net.bwie.jtp.dwd.order.job;

import net.bwie.realtime.jtp.common.utils.DorisUtil;
import net.bwie.realtime.jtp.common.utils.KafkaUtil;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class testjob {
    public static void main(String[] args) throws Exception {
        // 1. 执行环境-env
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);

        // 2. 数据源-source
        DataStream<String> dataStream = KafkaUtil.consumerKafka(env, "customer_login_log");
        dataStream.print();


        // 5. 触发执行-execute
        env.execute("JtpOrderDetailDorisDwdJob");
    }
}
